<?php

namespace hunma\queue;

use support\Log;
use Webman\RedisQueue\Consumer;

class TestConsumer implements Consumer
{
    /**
     * 队列名称
     *
     * @var string
     */
    public $queue = 'test_queue';

    /**
     * 连接名称
     *
     * @var string
     */
    public $connection = 'default';

    /**
     * 消费日志数据
     *
     * @param array $data 日志数据
     */
    public function consume($data)
    {
        echo "测试队列打印：".$data;
    }
}